/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 *  SRVConnectOperation.m - iPhoneSRV console for Surveyor SRV-1 and SVS 
 *
 *  Created by Nick Kitchener.  Copyright (C) 2009  Surveyor Corporation 
 *            and Nick Kitchener.  All rights reserved.
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details (www.gnu.org/licenses)
 * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */

#import "SRVConnectOperation.h"

@implementation SRVConnectOperation
@synthesize blackfin;

-(id)initWithBlackfin:(SRVBlackfinController*)controller {
	if( self = [super init] ) {
		blackfin = controller;
		url = nil;
		port = -1;
	}
	return self;
}

-(id)initWithBlackfin:(SRVBlackfinController*)controller targetURL:(NSString*)tUrl targetPort:(int)tPort {
	if( self = [super init] ) {
		blackfin = controller;
		url = tUrl;
		port = tPort;
	}
	return self;
}

-(void)dealloc {
	blackfin = nil;
	[super dealloc];
}

-(void)main {
	@try {
		NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
		
		NSLog(@" %@: beginning execution", self);

		if(url!=nil) {
			[blackfin setTargetURL:url];
			[blackfin setPortNumber:port];
		}
		
		[blackfin performSelectorOnMainThread:@selector(openConnection:) withObject:nil waitUntilDone:YES];
				
		[self setupConnectionClient];
		do{
			CFRunLoopRunInMode(kCFRunLoopDefaultMode, 0.5, true);
		} while((!complete) && (![self isCancelled]));
		NSLog(@" %@ ending, complete=%i, isCancelled=%i", self, complete, [self isCancelled]);
		if( !expired ) {
			[expiryTimer invalidate];
			expiryTimer=nil;
		} else {
			// expired so, even if the streams opened, it's too late so we close it to ensure clean exit
			[blackfin performSelectorOnMainThread:@selector(closeConnection:) withObject:nil waitUntilDone:YES];
		}
		
		[self teardownConnectionClient];
		[self invokeControllerCallback];
		[self invokeCallback];
		[pool release];
		
		[self willChangeValueForKey:@"isFinished"];
		[self willChangeValueForKey:@"isExecuting"];
		executing = NO;
		finished = YES;
		[self didChangeValueForKey:@"isExecuting"];
		[self didChangeValueForKey:@"isFinished"];
	}
	@catch (NSException * e) {
		NSLog(@" %@: operation thread exception caught %@", self, e);
	}
	@finally {
		
	}
}

-(void)haveSpace:(CFWriteStreamRef)outputStream {
	complete = YES;
}

+(SRVConnectOperation*)connectWith:(SRVBlackfinController*)controller {
	return [[SRVConnectOperation alloc]initWithBlackfin:controller];
}

+(SRVConnectOperation*)connectWith:(SRVBlackfinController*)controller toURL:(NSString*)url onPort:(int)port{
	return [[SRVConnectOperation alloc]initWithBlackfin:controller targetURL:url targetPort:port];
}

@end
